package com.distribute.core.notify.redis.redisson;

import com.distribute.core.core.BaseNotifyMessage;
import com.distribute.core.notify.redis.RedisMessageListenerUtils;
import org.redisson.api.listener.MessageListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 接受通知消息，刷新缓存实现类
 * 初始化 channel
 *
 * @author chennengcheng
 * @date 2021-09-17 17:19
 * @remark
 */
public class RedssionNotifyMessageListener implements MessageListener<BaseNotifyMessage> {

    private static final Logger log = LoggerFactory.getLogger(RedssionNotifyMessageListener.class);

    @Override
    public void onMessage(CharSequence channel, BaseNotifyMessage msg) {
        RedisMessageListenerUtils.process(msg);
    }
}